//此模块是db数据库连接和方法封装
var mysql = require('mysql');
var pool  = mysql.createPool({    //创建
    connectionLimit : 10,    //线路总数
    host            : 'localhost',   //数据库连接地址
    user            : 'root',   //用户名
    password        : '',   //密码
    database        : 'music'   //数据库名
});

let db = {};
db.q = function (sql, params) {
    return new Promise((resolve,reject) => {
        pool.getConnection(function (err, connection) {
            if (err) {
                reject(err)  //如果出错就给回调函数传err，抛出错误，下面终止
                return;
            }
            connection.query(sql, params, function (error, results, fields) {    //sql,params传参
                connection.release();   //释放连接，一定要在回调函数前面，否则抛错误就无法释放
                // console.log(fields);  //当前数据库包含的信息，非数据
                if (error) {
                    reject(error);
                    return
                }else{
                    resolve(results)
                }
            });
        });
    })
};
module.exports=db